package jobs

// ExecRemote ...
// func ExecRemote(v dao.RemoteStorage, rlid string, lid string, Localfilepath string) error {
// 	var err error
// 	yuancheng := rs.NewRS(v.Host, v.Port, v.Username, v.Password, Localfilepath, v.Path)
// 	if v.Types == "ftp" {
// 		err = yuancheng.FtpUpload()
// 	} else if v.Types == "sftp" {
// 		f, err := yuancheng.NewSftp()
// 		if err != nil {
// 			return err
// 		}
// 		err = f.Upload()
// 	} else if v.Types == "Yserver" {
// 		filepackets, err := yuancheng.ReadBigFile()
// 		if err != nil {
// 			return err
// 		}
// 		ysuploadfile := new(dao.YsUploadFile)
// 		ysuploadfile.ID = ksuid.New().String()
// 		ysuploadfile.Lid = rlid
// 		ysuploadfile.SrcFilePath = filepackets.SrcFilePath
// 		ysuploadfile.UploadFileServerID = filepackets.UploadFileServerID
// 		ysuploadfile.Size = filepackets.Size
// 		ysuploadfile.PacketNum = filepackets.PacketNum
// 		if err = ysuploadfile.AddYsFileLog(err); err != nil {
// 			return err
// 		}
// 		for _, v := range filepackets.Packets {
// 			packetlog := dao.YsPacket{}
// 			packetlog.ID = ksuid.New().String()
// 			packetlog.Yid = ysuploadfile.ID
// 			packetlog.Offset = v.Offset
// 			packetlog.Status = 1
// 			packetlog.SortID = v.SortID
// 			packetlog.SrcPacketPath = v.Packetpath
// 			packetlog.UploadPacketURL = filepackets.PacketUploadURL + strconv.Itoa(v.SortID)
// 			if err = ysuploadfile.AddYsPacketLog(packetlog); err != nil {
// 				fmt.Println(err.Error())
// 				return err
// 			}
// 		}
// 		file, err := os.OpenFile(filepackets.SrcFilePath, os.O_RDONLY, os.ModePerm)
// 		if err != nil {
// 			for _, v := range filepackets.Packets {
// 				ysuploadfile.UpdateYspacketLog(v.SortID, err)
// 			}
// 			filepackets.UploadDone("2")
// 			return err
// 		}
// 		defer file.Close()
// 		alldoneerr := 0
// 		for _, v := range filepackets.Packets {
// 			packetErr := filepackets.CreatePacket(file, v)
// 			err := ysuploadfile.UpdateYspacketLog(v.SortID, packetErr)
// 			if err != nil {
// 				return err
// 			}
// 			if packetErr != nil {
// 				alldoneerr++
// 			}
// 		}
// 		if alldoneerr > 0 {
// 			err = filepackets.UploadDone("2")
// 			if err != nil {
// 				return err
// 			}
// 		} else {
// 			err = filepackets.UploadDone("0")
// 			if err != nil {
// 				return err
// 			}
// 		}

// 	}
// 	return err
// }
